package models

import "time"

type CustomKafkaMsg struct {
	ActionType string `json:"action_type"` // 消息类型
	MsgId      string `json:"msg_id"`      // 消息ID
	//BalancerKey string      `json:"balancer_key"` // 分区键 //如果需要考虑消息的顺序性，那么就需要设置相同的分区键。并且采用Hash算法，即设置writerConfig.Balancer = &kafka.Hash{}，保证同一个分区键的消息会被发送到同一个分区中。
	Data      interface{} `json:"data"`      // 消息内容
	Timestamp time.Time   `json:"timestamp"` // 消息时间戳
	UserId    string      `json:"user_id"`   //主要判断是否是私聊
	AppId     uint32      `json:"app_id"`    //发送平台、房间
}
